9165667aa3975900ed1f79fd6c612cfd2e05a01f,broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java,Broker2Client,resetOffset,#String#String#number#boolean#boolean#,127

Before Change


                    try {
                        this.brokerController.getRemotingServer().invokeOneway(entry.getKey(), request, 5000);
                        log.info("[reset-offset] reset offset success. topic={}, group={}, clientId={}",
                                new Object[]{topic, group, entry.getValue().getClientId()});
                    } catch (Exception e) {
                        log.error("[reset-offset] reset offset exception. topic={}, group={}",
                                new Object[]{topic, group}, e);

After Change


                    try {
                        this.brokerController.getRemotingServer().invokeOneway(entry.getKey(), request, 5000);
                        log.info("[reset-offset] reset offset success. topic={}, group={}, clientId={}",
                                topic, group, entry.getValue().getClientId());
                    } catch (Exception e) {
                        log.error("[reset-offset] reset offset exception. topic={}, group={}",
                                new Object[]{topic, group}, e);